const http = require('http');

const options = {
  hostname: 'localhost',
  port: 3002,
  path: '/api/status',
  method: 'GET'
};

const req = http.request(options, (res) => {
  let data = '';

  res.on('data', (chunk) => {
    data += chunk;
  });

  res.on('end', () => {
    try {
      const status = JSON.parse(data);
      console.log('📊 当前 MQTT 状态:');
      console.log('   连接状态:', status.connected ? '✅ 已连接' : '❌ 未连接');
      console.log('   已订阅主题:', status.subscribedTopics);
      console.log('   Client ID:', status.config.clientId);
      console.log('\n💡 如果没有订阅 device/DEV070，那么发布到该主题的消息不会被接收！');
    } catch (err) {
      console.error('❌ 解析响应失败:', err.message);
    }
  });
});

req.on('error', (err) => {
  console.error('❌ 请求失败:', err.message);
  console.log('提示: 请确保服务器正在运行 (node server.js)');
});

req.end();
